

namespace Stee.CAP8.MessageBus.Kafka.Constant
{
    public static class ConsumerConstants
    {
        /// <summary>
        /// Timer interval for re-subscription
        /// </summary>
        public const int TimerIntervalSubscribe = 3000;

        /// <summary>
        /// Timeout for mutex
        /// </summary>
        public const int MutexTimeout = 5000;


        /// <summary>
        /// Waits for the message offset in multiples of X before consumer commits.
        /// When set at 1, consumer will commit the current offset when
        /// the message offset value is divisible by 1 (commit once from every 1 messages).
        /// </summary>
        public const int MinimumOffsetCommitPeriod = 1;

        /// <summary>
        /// Waits for the message offset in multiples of X before consumer commits.
        /// When set at 5, consumer will commit the current offset when
        /// the message offset value is divisible by 5 (commit once from every 5 messages).
        /// </summary>
        public const int MaximumOffsetCommitPeriod = 5;
    }
}
